package com.seaboxdata.service.impl;

import com.seaboxdata.dao.HdfsDao;
import com.seaboxdata.entity.OldStrategyConfig;
import com.seaboxdata.service.HdfsDataAgeService;
import org.apache.hadoop.fs.FileSystem;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import java.io.IOException;

/**
 * @author
 * @create 2021-01-29 9:53
 **/
@Service
public class HdfsDataAgeServiceImpl implements HdfsDataAgeService {

    @Autowired
    private HdfsDao hdfsDao;

    @Override
    public void dataAge(OldStrategyConfig config) {
        String dataPath = config.getDataPath();
        FileSystem fileSystem = null;
        try {
            fileSystem = hdfsDao.getFileSystem();
            //fileSystem.
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

}
